package com.warm.orm.eq.sys.agent;

import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import com.easy.query.api.proxy.client.EasyEntityQuery;
import com.easy.query.api.proxy.entity.select.EntityQueryable;
import com.easy.query.core.api.pagination.EasyPageResult;
import com.easy.query.solon.annotation.Db;
import com.warm.core.page.TableDataInfo;
import com.warm.orm.domain.sys.SysConfig;
import com.warm.orm.domain.sys.proxy.SysConfigProxy;
import com.warm.orm.utils.DateParaUtils;
import com.warm.orm.utils.PageUtils;
import com.warm.system.api.orm.agent.SysConfigAgent;
import org.noear.solon.annotation.Component;
import org.noear.solon.data.dynamicds.DynamicDs;

import java.util.List;

/**
 * 参数配置 数据层 orm代理类
 *
 * @author warm
 */
@Component
public class SysConfigAgentImpl implements SysConfigAgent {

    @Db
    private EasyEntityQuery easyEntityQuery;

    /**
     * 根据键名查询参数配置信息
     *
     * @param configKey 参数键名
     * @return 参数配置信息
     */
    @Override
    public SysConfig checkConfigKeyUnique(String configKey) {
        return this.easyEntityQuery
                // FROM sys_config t
                .queryable(SysConfig.class)
                // WHERE t.config_key = {configKey} limit 1
                .where(t -> t.configKey().eq(configKey))
                .firstOrNull();
    }

    /**
     * 删除参数配置
     *
     * @param configId 参数ID
     * @return 结果
     */
    @Override
    public int deleteConfigById(Long configId) {
        return (int) this.easyEntityQuery.deletable(SysConfig.class).whereById(configId).executeRows();
    }

    /**
     * 批量删除参数信息
     *
     * @param configIds 需要删除的参数ID
     * @return 结果
     */
    @Override
    public int deleteConfigByIds(Long[] configIds) {
        return (int) this.easyEntityQuery
                .deletable(SysConfig.class)
                .whereByIds(Convert.toList(configIds))
                .executeRows();
    }

    @Override
    public SysConfig selectConfigNoLogin(String tenantId, String configKey) {
        SysConfig config = new SysConfig();
        config.setConfigKey(configKey);
        config.setTenantId(tenantId);
        return this.easyEntityQuery
                .queryable(SysConfig.class)
                .where(t -> {
                    t.tenantId().eq(tenantId);
                    t.configKey().eq(StrUtil.isNotBlank(configKey), configKey);
                })
                .firstOrNull();
    }

    /**
     * 新增参数配置
     *
     * @param config 参数配置信息
     * @return 结果
     */
    @Override
    public int insertConfig(SysConfig config) {
        return (int) this.easyEntityQuery
                .insertable(config)
                .executeRows();
    }

    /**
     * 查询参数配置信息
     *
     * @param config 参数配置信息
     * @return 参数配置信息
     */
    @DynamicDs("master")
    @Override
    public SysConfig selectConfig(SysConfig config) {
        return this.easyEntityQuery
                .queryable(SysConfig.class)
                .where(t -> {
                    t.configId().eq(ObjUtil.isNotNull(config.getConfigId()), config.getConfigId());
                    t.configKey().eq(StrUtil.isNotBlank(config.getConfigKey()), config.getConfigKey());
                })
                .firstOrNull();
    }

    /**
     * 通过ID查询配置
     *
     * @param configId 参数ID
     * @return 参数配置信息
     */
    @Override
    public SysConfig selectConfigById(Long configId) {
        return this.easyEntityQuery
                .queryable(SysConfig.class)
                .whereById(configId)
                .firstOrNull();
    }

    /**
     * 查询参数配置列表
     *
     * @param config 参数配置信息
     * @return 参数配置集合
     */
    @Override
    public List<SysConfig> selectConfigList(SysConfig config) {
        return this.buildQuery(config).toList();
    }

    private EntityQueryable<SysConfigProxy, SysConfig> buildQuery(SysConfig config) {
        return this.easyEntityQuery
                .queryable(SysConfig.class)
                .where(t -> {
                    // AND config_name like concat('%', #{configName}, '%')
                    t.configName().like(StrUtil.isNotBlank(config.getConfigName()), config.getConfigName());
                    // AND config_type = #{configType}
                    t.configType().eq(StrUtil.isNotBlank(config.getConfigType()), config.getConfigType());
                    // AND config_key like concat('%', #{configKey}, '%')
                    t.configKey().like(StrUtil.isNotBlank(config.getConfigKey()), config.getConfigKey());
                    // AND date_format(create_time,'%y%m%d') >= date_format(#{params.beginTime},'%y%m%d')
                    // AND date_format(create_time,'%y%m%d') <= date_format(#{params.endTime},'%y%m%d')
                    t.createTime().rangeClosed(
                            ObjUtil.isNotNull(config.getParams().get("beginTime")),
                            DateParaUtils.getStartDate(config),
                            ObjUtil.isNotNull(config.getParams().get("endTime")),
                            DateParaUtils.getEndDate(config)
                    );
                });
    }

    /**
     * 查询参数配置列表
     *
     * @param config 参数配置信息
     * @return 参数配置集合
     */
    @Override
    public TableDataInfo<SysConfig> selectConfigPage(SysConfig config) {
        PageUtils.startPage();
        EasyPageResult<SysConfig> pageResult = this.buildQuery(config)
                .toPageResult(PageUtils.getLocalPage().getPageNum(), PageUtils.getLocalPage().getPageSize());
        return new TableDataInfo(pageResult.getData(), (int) pageResult.getTotal());
    }

    /**
     * 修改参数配置
     *
     * @param config 参数配置信息
     * @return 结果
     */
    @Override
    public int updateConfig(SysConfig config) {
        return (int) this.easyEntityQuery.updatable(config).executeRows();
    }
}
